package com.we.flink.dcapiuserlabel.table;

import java.sql.Timestamp;

public class TableTask {
    public static final String KFKTABLE = "fdm.rrd07_task";
    public static final String QUERYSQL =
            "select user_id as connect_id, create_time from " + KFKTABLE;

    public int connect_id;
    public Timestamp create_time;

    public TableTask() {}

    public TableTask(int connect_id, Timestamp create_time) {
        this.connect_id = connect_id;
        this.create_time = create_time;
    }

    public int getConnect_id() {
        return connect_id;
    }

    public Timestamp getCreate_time() {
        return create_time;
    }
}
